package com.zhangdi.mgsync.core.thread;

/**
 * @author zhangdi
 * @version 1.0
 * @date 2021.10.21 14:08
 */
public interface SyncWorker extends Runnable {
    void startAtTime();
    String name();
    WorkerState state();
    boolean isRunning();
    boolean shutdown();

    boolean isShutdown();

    /**
     * 只停止遍历游标
     * 待发送消息后再关闭监听
     */
    void stopListener();

    boolean tryReStartListener();

    void batchPostTimeoutTasker();
}
